package cn.wjee.gradle.flink.config;

/**
 * Flink Config
 *
 * @author listening
 */
public class FlinkExtConfig {
    /**
     * Flink Host
     */
    private String host = "127.0.0.1";
    /**
     * Flink Rest Port
     */
    private Integer restPort = 8081;
    /**
     * Flink Rpc Port
     */
    private Integer rpcPort = 6123;
    /**
     * Deploy Job Name
     */
    private String jobName = "";
    /**
     * JobJar Location
     */
    private String jobJar = "";
    /**
     * Running Profile
     */
    private String profile = "";
    /**
     * Default Parallelism
     */
    private Integer parallelism = 1;
    /**
     * SavePoint
     */
    private String savePoint = "";
    /**
     * JOB Args, eg: --profile, env
     */
    private String[] jobArgs = new String[]{"--profile", "dev"};


    public String getHost() {
        return host;
    }

    public void setHost(String host) {
        this.host = host;
    }

    public Integer getRestPort() {
        return restPort;
    }

    public void setRestPort(Integer restPort) {
        this.restPort = restPort;
    }

    public Integer getRpcPort() {
        return rpcPort;
    }

    public void setRpcPort(Integer rpcPort) {
        this.rpcPort = rpcPort;
    }

    public String getJobName() {
        return jobName;
    }

    public void setJobName(String jobName) {
        this.jobName = jobName;
    }

    public String getJobJar() {
        return jobJar;
    }

    public void setJobJar(String jobJar) {
        this.jobJar = jobJar;
    }

    public String getProfile() {
        return profile;
    }

    public void setProfile(String profile) {
        this.profile = profile;
    }

    public Integer getParallelism() {
        return parallelism;
    }

    public void setParallelism(Integer parallelism) {
        this.parallelism = parallelism;
    }

    public String getSavePoint() {
        return savePoint;
    }

    public void setSavePoint(String savePoint) {
        this.savePoint = savePoint;
    }

    public String[] getJobArgs() {
        return jobArgs;
    }

    public void setJobArgs(String[] jobArgs) {
        this.jobArgs = jobArgs;
    }
}
